package com.springcloud.message;

import org.springframework.cloud.stream.annotation.EnableBinding;
import org.springframework.cloud.stream.annotation.StreamListener;

/**
 * @author: XYZC
 * @Date: 2021/10/29 10:03
 * @Description: null
 */
@EnableBinding(ISink.class)
public class RecieveService {

    @StreamListener(ISink.INPUT)
    public void recieve(Object msg){
        System.err.println("监听消息："+msg.toString());
    }
}
